package com.holly.unit.kafka.model;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.ToString;

/**
 * kafka Topic
 * @author pengpeng
 *
 */
@Data
@AllArgsConstructor
@ToString
public class Ktopic {
	/**
	 * topic 订阅主题 名称
	 */
	private String name;
	/**
	 * 主题 分区个数
	 */
	private int numPartitions;
	/**
	 * 主题 副本个数
	 */
	private int replicationFactor;
	
	/**
	 * 订阅主题
	 */
	private String topic;//订阅主题
	
	/**
	 * 订阅分区
	 */
	private Integer partition;//分区

	public Ktopic(String name, int numPartitions, int replicationFactor) {
		super();
		this.name = name;
		this.numPartitions = numPartitions;
		this.replicationFactor = replicationFactor;
	}

	public Ktopic(String topic, Integer partition) {
		super();
		this.topic = topic;
		this.partition = partition;
	}
	
	
	
}
